<?php

$config=[
        'host' => '127.0.0.1',
        'port' => 3306,
        'user' => 'root',
        'password' => 'Qq!990979940',
        'database' => 'test',
        'charset' => 'utf8', //指定字符集
        'timeout' => 2,  // 可选：连接超时时间（非查询超时时间），默认为SW_MYSQL_CONNECT_TIMEOUT（1.0）
];

$mysql=new swoole\mysql;


//数据写入,数据整理
$mysql->connect($config,function ($db,$res){
        //错误提示
       if($res==false){
          var_dump($db->connect_errno);
           return;
       }
        //查询
       $sql='select  * from test';
       $db->query($sql,function ($db,$res){
              $sql="insert into test (name) values('peter')";
              $db->query($sql,function ($db,$res) use($sql){
                   //继续执行sql语句
                  if($res){
                      echo $db->insert_id;
                  }
                  //同步的执行
                  $con=mysqli_connect("127.0.0.1",'root','Qq!990979940','test');
                  var_dump($con->query($sql));
                  $db->query($sql,function ($db,$res) use($sql){
                        echo '回调方法';
                  });
              });
       });

       //var_dump($res);
      // $db->close();
});


$mysql->on('close',function ($db){
    //var_dump('关闭连接');
});


echo '异步程序'.PHP_EOL;

//即时返回给客户端
